package main
//
//// 将用户信息用redis队列里面写，赛选出可以匹配的用户
//
//import (
//	"hytx_sync/pkg/setting"
//	"hytx_sync/models"
//	"hytx_sync/pkg/logging"
//	"hytx_sync/pkg/gredis"
//	"fmt"
//	"time"
//	"strconv"
//	"sync"
//)
//
//func init() {
//	setting.Setup()
//	models.Setup()
//	logging.Setup()
//	gredis.Setup()
//}
//
//var wg sync.WaitGroup
//var dataMap = make(map[int]int)
//
//func main() {
//	InterPushUserInfo := models.InterPushUserInfo{}
//	last_id, err := InterPushUserInfo.GetLastId() // 查询匹配列表最后个id
//	if err != nil {
//		fmt.Println(err)
//	}
//
//	for i := 1; i <= last_id.ID; i++ {
//		wg.Add(1)
//		go selectData(i)
//	}
//	wg.Wait()
//
//	// 写入redis
//	for i := 0; i < 3; i++ {
//		wg.Add(1)
//		go pushRedis(dataMap)
//	}
//	wg.Wait()
//}
//
//func selectData(i int) {
//	defer wg.Add(-1)
//
//	// 查询单个匹配用户
//	in := models.InterPushUserInfo{
//		ID:        i,
//		IsEnabled: 1,
//	}
//	i_info, err := in.Get()
//
//	if err != nil {
//		return
//	}
//
//	// 查询个人信息
//	c := models.Card{
//		UserId: i_info.UserId,
//	}
//	_, err = c.Get()
//	if err != nil {
//		return
//	}
//
//	// 查询个人网页的模板
//	p := models.PersonalPageTemplateUser{
//		UserId: i_info.UserId,
//	}
//	_, err = p.Get()
//	if err != nil {
//		return
//	}
//
//	conn := gredis.RedisConn.Get()
//	defer conn.Close()
//
//	dataMap[i] = i_info.MeProvinceId
//
//}
//
//// 写入redis
//func pushRedis(data map[int]int) {
//	defer wg.Add(-1)
//
//	conn := gredis.RedisConn.Get()
//	defer conn.Close()
//
//	// 写入redis
//	for key, value := range data {
//		// 写入redis
//		sadd_match_user := time.Now().Format("20060102") + "_" + strconv.Itoa(value) + "_match_user"
//		_, err := conn.Do("RPUSH", sadd_match_user, key)
//
//		// 删除昨天的信息
//		yesterday := time.Now().AddDate(0, 0, -1).Format("20060102") + "_" + strconv.Itoa(value) + "_match_user"
//		_, err = conn.Do("del", yesterday)
//
//		if err == nil {
//			fmt.Println(key, "添加成功")
//		} else {
//			fmt.Println(key, "添加失败")
//		}
//	}
//
//}
